Coroutines Extensions/io.github.rain991.extensions

Package-level declarations

Functions

suspend fun <T, R> Iterable<T>.mapAsync(transform: suspend (T) -> R): List<R>

Transforms all elements of the iterable concurrently.

fun <T> ERROR CLASS: Symbol not found for Flow<T>.pairwise(): ERROR CLASS: Symbol not found for Flow<ERROR CLASS: Symbol not found for Pair<T, T>>

For each emission after the first, emits a Pair(previous, current).

raceWith

suspend fun <T> ERROR CLASS: Symbol not found for Flow<T>.raceWith(other: ERROR CLASS: Symbol not found for Flow<T>): T

Returns the value from flow that emits first.

retryWithExponentialBackoff

fun <T> ERROR CLASS: Symbol not found for Flow<T>.retryWithExponentialBackoff(maxAttempts: Int, initialDelay: ERROR CLASS: Symbol not found for Duration, multiplier: Double = 2.0, retryOn: (Throwable) -> Boolean = { true }): ERROR CLASS: Symbol not found for Flow<T>

Retries the flow when it fails, while increasing the delay between retries.

timeoutOrNull

fun <T> ERROR CLASS: Symbol not found for Flow<T>.timeoutOrNull(timeout: ERROR CLASS: Symbol not found for Duration): ERROR CLASS: Symbol not found for Flow<T?>

Emits the first value from the upstream flow or null if no value is emitted within the given timeout.

withDefault

fun <T> ERROR CLASS: Symbol not found for Flow<T>.withDefault(default: T): ERROR CLASS: Symbol not found for Flow<T>

Emits the provided default value if the upstream flow is empty.

fun <T> ERROR CLASS: Symbol not found for Flow<T>.withDefault(default: T, shouldDefault: (Throwable) -> Boolean): ERROR CLASS: Symbol not found for Flow<T>

Emits the provided default value if the upstream flow is empty and .

withFallback

fun <T> ERROR CLASS: Symbol not found for Flow<T>.withFallback(fallbackWhen: (Throwable) -> Boolean = { true }, fallback: () -> ERROR CLASS: Symbol not found for Flow<T>): ERROR CLASS: Symbol not found for Flow<T>

Emits from upstream flow, switches to fallback flow in case of an exception.